home *** CD-ROM | disk | FTP | other *** search
/ Skunkware 5 / Skunkware 5.iso / src / Tools / freeWAIS-sf-1.1 / ir / server-single.c < prev    next >
Encoding:
C/C++ Source or Header  |  1994-12-13  |  20.6 KB  |  745 lines
  1. /* WIDE AREA INFORMATION SERVER SOFTWARE    
  2.    No guarantees or restrictions.  See the readme file for the full standard 
  3.    disclaimer.
  4.    5.29.90    Harry Morris, morris@think.com
  5. */
  6.  
  7. /* Copyright (c) CNIDR (see ../COPYRIGHT) */
  8.  
  9.  
  10. /* this file is a server process for a unix machine that takes input from 
  11.    standard in or from a socket and searches the local search engine on the 
  12.    unix box.
  13.    originally written by harry morris.
  14.    modified by brewster kahle. 7/90
  15.    6.xx.90    Brewster - initial implementation of stdio interface
  16.    7.xx.90    Patrick Bray - support for headers and forking processes
  17.    90.07.31    Ephraim - support for logging 
  18.  
  19.    91.03.03     Jonathan - set searchLog to log_out.
  20.    91.05.23    Jonathan - added fork process for indexer.
  21.                            Fixed version display so it exits.
  22.    91.05.25     Jonathan - added setuid.
  23.    
  24.    Tue Jul  9 12:11:02 1991 -- Michael Haberler mah@wu-wien.ac.at
  25.  
  26.                 Added semi-intelligent INFO database indexing (only done if
  27.         any of the .src files is newer than INFO.dct)
  28.         
  29.         Locking against multiple concurrent INFO rebuilds if 
  30.         running under inetd
  31.  
  32.         Use scandir() for directory operations
  33.  
  34.         Works under inetd as well as standalone. Here are my inetd.conf
  35.            entries (not the missing userid in the Ultrix inetd.conf!):
  36.  
  37.    hpux 7.0/800, Interactive/386 2.2.1:
  38.     z3950 stream tcp nowait root /usr/local/etc/waisserver waisserver -s \
  39.         -d /usr/logins/mah/wais-sources
  40.  
  41.    Ultrix 4.1:
  42.     z3950 stream tcp nowait /usr/local/etc/waisserver waisserver -s \
  43.         -d /usr/logins/mah/wais-sources
  44.  
  45.    Also, add the next line to /etc/services, and tickle your YP server:
  46.     z3950           210/tcp         # wide area information server (wais)
  47.  
  48.  * $Log: server-single.c,v $
  49.  * Revision 1.12  1994/12/13  19:50:18  pfeifer
  50.  * chip@chinacat.unicom.com (Chip Rosenthal) patches.
  51.  * Excluding the merge of libinv and libwais
  52.  *
  53.  * Revision 1.10  1994/10/11  14:39:04  pfeifer
  54.  * convex
  55.  *
  56.  * Revision 1.9  1994/10/06  13:28:31  pfeifer
  57.  * Patch from Mariusz Niewczas
  58.  *
  59.  * Revision 1.8  1994/09/09  09:00:28  pfeifer
  60.  * Fixed the MAX_OCCURANCES - STOP_WORD_FLAG bug
  61.  *
  62.  * Revision 1.7  1994/09/08  16:42:23  pfeifer
  63.  * make BSD happy
  64.  *
  65.  * Revision 1.6  1994/09/06  16:54:42  pfeifer
  66.  * Added #include <netinet/in.h>
  67.  *
  68.  * Revision 1.5  1994/08/08  07:32:50  pfeifer
  69.  * Moved wais_log_file_name and waislogfile to cutil.[ch]
  70.  *
  71.  * Revision 1.3  1994/05/20  12:57:05  pfeifer
  72.  * beta
  73.  *
  74.  * Revision 1.2  1994/03/08  21:06:41  pfeifer
  75.  * Patchlevel 04
  76.  *
  77.  * Revision 1.1  1993/02/16  15:05:35  freewais
  78.  * Initial revision
  79.  *
  80.  * Revision 1.8  92/05/10  14:49:06  jonathan
  81.  * Updated for release
  82.  * 
  83.  * Revision 1.7  92/03/05  07:08:23  shen
  84.  * add two more dummy arguments to call to init_search_engine
  85.  * 
  86.  * Revision 1.6  92/02/16  12:32:42  jonathan
  87.  * Removed all code refering to use_stdio, since it's not a valid choice in
  88.  * this server.
  89.  * 
  90.  * Revision 1.5  92/02/12  13:42:04  jonathan
  91.  * Changed server date.
  92.  * 
  93.  * Revision 1.4  92/02/12  13:41:18  jonathan
  94.  * Added "$Log" so RCS will put the log message in the header
  95.  * 
  96. */
  97.  
  98. #define SERVER_DATE "Sun May 10 1992"
  99.  
  100. #ifndef lint
  101. static char *RCSid = "$Header: /usr/local/ls6/src+data/src/freeWAIS-sf/ir/RCS/server-single.c,v 1.12 1994/12/13 19:50:18 pfeifer Exp $";
  102. #endif
  103.  
  104. #define INFO_DICT    "INFO.dct"
  105. #define LOCKFILE    "/tmp/INFO.lock" /* while re-indexing INFO */
  106. #define NAPTIME     1             /* seconds */
  107. #define MAXNAPTIME  60        /* wait up to a minute for indexer to finish */
  108.  
  109. #include "server.h"
  110. #include "sockets.h"
  111. /* #include <sys/types.h> */
  112. #include <sys/stat.h>
  113. #ifdef USG
  114. #ifdef HAVE_SYS_FCNTL_H
  115. #include <sys/fcntl.h>
  116. #else
  117. #include <fcntl.h>
  118. #endif /* HAVE_SYS_FCNTL_H */
  119. #else
  120. #include <sys/file.h>
  121. #endif
  122. #ifdef SYSV            
  123. #define SIGCHLD SIGCLD
  124. #endif
  125. #include <signal.h>
  126. /* #include <string.h> */
  127. #include "irdirent.h"
  128. #include "panic.h"
  129. #include "ustubs.h"
  130. #include "transprt.h"
  131. #include "wmessage.h"
  132. #include "ir.h"
  133. #include "wprot.h"
  134. #include "cutil.h"
  135. #include "futil.h"
  136. #include "irext.h"
  137.  
  138. /* to create the INFO index */
  139. #include "irtfiles.h"
  140. #include "irfiles.h"
  141. #include "irhash.h"
  142. #include "version.h"
  143.  
  144. /* for address decoding */
  145.  
  146. #if !defined(ultrix) && !defined(__convex__)
  147. #ifdef HAVE_SYS_SOCKET
  148. #include <sys/socket.h>
  149. #endif
  150. #endif
  151. #ifdef HAVE_NETINET_IN_H 
  152. #if BSD != 199103
  153. #include <netinet/in.h>
  154. #endif
  155. #endif
  156. #ifndef ultrix
  157. #ifdef HAVE_SYS_SOCKET
  158. #include <netdb.h>
  159. #endif
  160. #endif
  161. #include <arpa/inet.h>
  162.  
  163. #include <setjmp.h>
  164.  
  165. #ifdef HAVE_SYS_SELECT_H
  166. #include <sys/select.h>
  167. #endif
  168.  
  169. static jmp_buf jbuf;
  170.  
  171. static long bufferSize = BUFSZ; /* how much we are using
  172.                                    (we get one of these per process) */
  173.  
  174. static FILE *current_client;
  175. static struct itimerval new, old;
  176.  
  177. /*---------------------------------------------------------------------------*/
  178. #define TIMEOUT_LENGTH 5 /* 5 second timeout. 
  179.                 Since this is only in the handle - client code,
  180.                 I don't want it to wait too long.  
  181.                 The bytes should come quickly
  182.               */
  183. #define IDLE_TIME "5 seconds"
  184.  
  185. long
  186.  handle_client(in,out, index_directory)
  187. FILE* in;
  188. FILE* out;
  189. char *index_directory;
  190. { 
  191.   char buf[BUFSZ];        /* contains the message and header */
  192.   char *bufPtr ;        /* points at the begining of the z3950 */
  193.   long size;            /* bytes in the z3950 message */
  194.   WAISMessage header;        /* for storing the header */
  195.   long i;
  196.   long bytesLeft;
  197.   long nextChar;
  198.   int  jmpres;
  199.  
  200.   new.it_interval.tv_sec = 0;
  201.   new.it_interval.tv_usec = 0;
  202.   new.it_value.tv_sec = TIMEOUT_LENGTH;
  203.   new.it_value.tv_usec = 0;
  204.  
  205.   if ((jmpres = setjmp(jbuf)) != 0) {
  206.     if (jmpres == 2) return EOF; /* because we're here by timeout */
  207.   } else {
  208.     /* try to read the header */
  209.     for (i = 0; i < HEADER_LENGTH; i++)
  210.       { 
  211.     setitimer(ITIMER_REAL, &new, NULL);
  212.     nextChar = fgetc(in);
  213.     if (nextChar == EOF)    /* my connection exited, so will I */
  214.       { 
  215.         setitimer(ITIMER_REAL, &old, NULL);
  216.         return EOF;
  217.       }
  218.     else
  219.       buf[i] = (char)nextChar;
  220.       }
  221.     setitimer(ITIMER_REAL, &old, NULL);
  222.     /* parse the header */
  223.     readWAISPacketHeader(buf,&header);
  224.  
  225.     /* make sure we have the right version.  
  226.        If we dont, we dont know what to do. */
  227.     if (header.hdr_vers > HEADER_VERSION)
  228.       panic("Incompatable header versions (Current version: %d, supplied version: %d.", 
  229.         HEADER_VERSION, header.hdr_vers) ;
  230.  
  231.     /* determine the size of the z3950 message */
  232.     {
  233.       char length_array[11];
  234.       strncpy(length_array, header.msg_len, 10);
  235.       length_array[10] = '\0';
  236.       size = atol(length_array);
  237.     }
  238.  
  239.     /* set bufPtr to start the z3950 message */
  240.     bufPtr = buf + HEADER_LENGTH ;
  241.  
  242.     /* read the z3950 message */
  243.     for (i = 0; i < size ; i++) {
  244.       setitimer(ITIMER_REAL, &new, NULL);
  245.       if ((buf[i + HEADER_LENGTH] = (char)fgetc(in)) == EOF)
  246.     return -1;
  247.     }
  248.  
  249.     setitimer(ITIMER_REAL, &old, NULL);
  250.     rewind(in);
  251.  
  252.     /* decode the z3950 if necessary */
  253.     transportDecode((long)header.encoding,bufPtr,&size);
  254.      
  255.     /* XXX handle compression options */
  256.  
  257.     /* process it the z3950 */
  258.     bytesLeft = bufferSize;
  259.  
  260.     size = interpret_buffer(bufPtr,size,bufPtr,bytesLeft,
  261.                 &bufferSize,(long)header.hdr_vers,
  262.                 index_directory); 
  263.  
  264.     /* re-encode the message if necessary */
  265.     transportCode((long)header.encoding,bufPtr,&size); 
  266.  
  267.     /* XXX handle compression options */
  268.  
  269.     /* write the new header */
  270.     writeWAISPacketHeader(buf,size,
  271.               (long)header.msg_type,header.server,
  272.               (long)header.compression,(long)header.encoding,
  273.               (long)header.hdr_vers);
  274.  
  275.     /* write the whole response to the output file */
  276.     for (i = 0; i < size + HEADER_LENGTH; i++)
  277.       fputc(buf[i],out) ;
  278.  
  279.     fflush(out);        /* flush any file buffers */
  280.     rewind(out);
  281.  
  282.     return 0;
  283.   }
  284. }
  285.  
  286. /*---------------------------------------------------------------------------*/
  287.  
  288. #ifndef ISC
  289. static void breakKey _AP((long s1,long s2,struct sigcontext* s3,char* s4));
  290. #endif
  291.  
  292. static void
  293. breakKey (s1,s2,s3,s4)
  294. long s1;
  295. long s2;
  296. struct sigcontext *s3;
  297. char *s4;
  298. {
  299.   waislog(WLOG_HIGH, WLOG_ERROR, "got a ^c");
  300.   exit (-1);
  301. }
  302.  
  303. /*---------------------------------------------------------------------------*/
  304.  
  305. void
  306. childhandler(sig, code, scp, addr)
  307. long sig, code;
  308. struct sigcontext *scp;
  309. char *addr;
  310. {
  311.   wait(NULL);            /* give the kid a decent burial */
  312.   signal (SIGCHLD, childhandler);  /* Dave Judd - IRIX requires resetting signal */
  313. }
  314.  
  315. /*---------------------------------------------------------------------------*/
  316.  
  317. void
  318. server_alarmhandler(sig, code, scp, addr)
  319. long sig, code;
  320. struct sigcontext *scp;
  321. char *addr;
  322. {
  323.   setitimer(ITIMER_REAL, &old, NULL);
  324.   if(current_client != NULL) {
  325.     waislog(WLOG_HIGH, WLOG_CLOSE,
  326.         "Client idle longer %s during Read - Closing client connection.", IDLE_TIME);
  327.     longjmp(jbuf, 2);
  328.   }
  329.   else  {
  330.     waislog(WLOG_HIGH, WLOG_ERROR,
  331.         "Bogus timer signal.  What's the deal?");
  332.   }
  333. }
  334.  
  335. /*---------------------------------------------------------------------------*/
  336.  
  337. void
  338. seghandler(sig, code, scp, addr)
  339. long sig, code;
  340. struct sigcontext *scp;
  341. char *addr;
  342. {
  343.   waislog(WLOG_HIGH, WLOG_CLOSE,
  344.       "Segmentation violation.  Bummer. Closing server and exiting.");
  345.   exit(0);
  346. }
  347.  
  348. /*---------------------------------------------------------------------------*/
  349.  
  350. void
  351. bushandler(sig, code, scp, addr)
  352. long sig, code;
  353. struct sigcontext *scp;
  354. char *addr;
  355. {
  356.   waislog(WLOG_HIGH, WLOG_CLOSE,
  357.       "Bus error.  Bummer. Closing server and exiting.");
  358.   exit(0);
  359. }
  360.  
  361. /*---------------------------------------------------------------------------*/
  362.  
  363. #include <pwd.h>
  364.  
  365. int finduid(name)
  366. char *name;
  367. {
  368.   struct passwd *pwent;
  369.  
  370.   if ((pwent = getpwnam(name)) == NULL) {
  371.     return -1;
  372.   }
  373.  
  374.   return(pwent->pw_uid);
  375. }
  376.  
  377. static  char *index_dir = NULL;
  378. static  time_t info_change_time;
  379. static  int indexing_needed = 0;
  380. static  char *info_dict = INFO_DICT;
  381.  
  382. extern int alphasort();
  383.  
  384. /* selecttion function for scandir()
  385.  * trigger on ".src" extension, regular file, and != "INFO.src"
  386.  * Indexing is needed if any of the .src files is younger than 
  387.  * INFO.dct
  388.  */
  389. static int
  390. srcfiles(e)
  391.     struct dirent *e;
  392. {
  393.     struct stat sb;
  394.     char *lastdot = strrchr(e->d_name,'.');
  395.     int candidate;
  396.  
  397.     candidate =    lastdot && 
  398.           (stat(merge_pathnames(e->d_name,index_dir), &sb) >= 0) && 
  399.           ((sb.st_mode & S_IFMT) == S_IFREG) &&
  400.           !strcmp(lastdot,source_ext) && 
  401.           strcmp(e->d_name,info_dict); /* whew */
  402.  
  403.         if (candidate) {
  404.         indexing_needed |= (sb.st_mtime > info_change_time);
  405.         return 1;
  406.     }
  407.     return 0;
  408. }
  409.  
  410.  
  411. /*---------------------------------------------------------------------------*/
  412.  
  413. #include <sys/types.h>
  414. #include <sys/time.h>
  415.  
  416. typedef struct _client_connection {
  417.   FILE *file;
  418.   long buffersize;
  419.   long pid;
  420.   long line;
  421. } client_connection, *Client_connection;
  422.  
  423. void
  424. main(argc,argv)
  425. int argc;
  426. char* argv[];
  427. { 
  428.   fd_set fds;
  429.   FILE *file;
  430.   client_connection clients[200];
  431.   int numclients, i;
  432.   long socket;
  433.   char *next_argument = next_arg(&argc, &argv), *command_name;
  434.   long tcp_port = 210;        /* tcp_port to use */
  435.   /* char *wais_log_file_name = NULL; */    /* name of file for error output */
  436.   int child_proc;        /* for the child process id */
  437.   char *uid_name = "root";    /* user id so setuid if root */
  438.   int uid = 0;            /* if not specified, leave as root. */
  439.   long cm_mem_percent = 0;      /* default */
  440.   int child,lockfd;
  441.   struct stat statbuf;
  442.   struct dirent **list;
  443.   int n_files,fd;    
  444.   int naptime = 0;
  445.   extern int errno;
  446.   extern char *sys_errlist[];
  447.   static long current_id = 1, current_log_line = 0;
  448.   dataopsrec    dataops;  
  449.  
  450.   command_name = next_argument;
  451.  
  452. /* dgg -- must duplicate mods to irbuild.c, here is mini-build of INFO.src */
  453.   dataops.separator_function= NULL;
  454.   dataops.header_function= NULL;
  455.   dataops.date_function= NULL;
  456.   dataops.finish_header_function= NULL;
  457.   dataops.type= "WSRC";
  458.   dataops.wordDelimiter= wordbreak_notalnum;
  459.   dataops.addseparatorwords= false;
  460.   dataops.extraheaderweight= true;
  461.   dataops.repeat_weight= 1;
  462.   dataops.minwordlen= 2;
  463.   stop_list_file("\0");
  464.   gDelimiters[0]= '\0';  
  465.   wordDelimiter= wordbreak_notalnum;   
  466. /* dgg -- end new inits */
  467.  
  468.   getitimer(ITIMER_REAL, &old);
  469.   for(i = 0; i < 200; i++)
  470.     clients[i].file = NULL;
  471.  
  472.   if (argc == 0){
  473.     printf("Usage: %s [-p [port_number]] [-d directory] [-u user] [-v] [-cmmem percent]\n",
  474.        command_name);
  475.     printf(" -p [port] listen to the port.  If the port is supplied, then\n");
  476.     printf("    that tcp_port number is used.  If it is not supplied \n");
  477.     printf("    then the Z39.50 port (210) is used.\n");
  478.     printf(" -d directory: means to use the directory as the source of databases.\n");
  479.     printf("    Defaults to the current directory.\n");
  480.     printf(" -e [file]: set log output to file, or /dev/null if not specified.\n");
  481.     printf(" -u user: if started as root, setuid to user after startup.\n");
  482.     printf(" -cmmem number: percentage of CM memory to use (CM code only).\n");
  483.     printf(" -v prints the version.\n");
  484.     exit(1);
  485.   }
  486.   if(NULL == (next_argument = next_arg(&argc, &argv))){
  487.     printf("No arguments specified\n");
  488.     exit(0);
  489.   }
  490.   while((next_argument != NULL) &&
  491.     ('-' == next_argument[0])){
  492.     /* then we have an argument to process */
  493.     if (0 == strcmp("-p", next_argument)){
  494.       char *peek_argument = peek_arg(&argc, &argv);
  495.       if ((NULL != peek_argument) && /* if we are not out of args */
  496.       ('-' != peek_argument[0])){ { /* and the next isn't an option... */
  497.         /* get the port number */
  498.         tcp_port = atoi(next_arg(&argc, &argv));
  499.       }            /* end if (explicit tcp_port) */
  500.                     }
  501.     }                /* end if (-p) */
  502.  
  503.     else if (0 == strcmp("-e", next_argument)) {
  504.       char *peek_argument = peek_arg(&argc, &argv);
  505.       wais_log_file_name = "/dev/null"; /* default to /dev/null */
  506.       if ((peek_argument != NULL) &&
  507.       ('-' != peek_argument[0])) {
  508.     wais_log_file_name = next_arg(&argc, &argv);
  509.       }                /* end if (explicit log file) */
  510.     }                /* end if (-e) */
  511.     else if (0 == strcmp("-d", next_argument)) {
  512.       index_dir = next_arg(&argc, &argv);
  513.     }
  514.     else if (0 == strcmp("-v", next_argument)) {
  515.       printf("%s: %s, %s\n", command_name, VERSION, SERVER_DATE);
  516.     }
  517.     else if (0 == strcmp("-u", next_argument)) {
  518.       uid_name = next_arg(&argc, &argv);
  519.       if((uid = finduid(uid_name)) < 0)
  520.     panic("Couldn't find user %s.", uid_name);
  521.     }
  522.     else if(0 == strcmp("-cmmem", next_argument)){
  523.       if(NULL == (next_argument = next_arg(&argc, &argv)))
  524.     panic("Expected a number (1-100) for percentage of memory to use");
  525.       cm_mem_percent = atol(next_argument);
  526.       if(cm_mem_percent < 1)
  527.     panic("The -cmmem argument should not be less than 1 and less than 100");
  528.       if(cm_mem_percent > 100)
  529.     panic("Warning: The -cmmem parameter was %ld%%. It should be between 1-100.", cm_mem_percent);
  530.     }
  531.     else{
  532.       panic("Don't recognize the %s option", next_argument);
  533.     }
  534.     next_argument = next_arg(&argc, &argv);
  535.   }                /* end while (more arguments) */
  536.  
  537.   if (wais_log_file_name == NULL) {
  538.     wais_log_file_name = "/dev/null";
  539.     waislogfile = stderr;
  540.   }
  541.   else waislogfile = NULL;
  542.   
  543.   if(0 != init_search_engine(index_dir, false, true, cm_mem_percent,0,0))
  544.     panic("unable to initialize search engine");
  545.  
  546. #ifdef AUTO_INDEX
  547.  
  548.   index_dir = index_dir ? index_dir : ".";  
  549.   info_dict = s_strdup(merge_pathnames(info_dict,index_dir));
  550.   
  551.   /* remember timestamp on INFO.dct if rebuilding needed 
  552.    * If it doesnt exist, it's assumed to be *very* old, to force
  553.    * re-indexing
  554.    */
  555.   info_change_time = (stat(info_dict,&statbuf) == -1) ? 0 : statbuf.st_mtime;
  556.   
  557.   /* compare with candidates */
  558.  
  559.   if ((n_files = scandir(index_dir, &list, srcfiles, alphasort)) < 0) {
  560.     waislog(WLOG_HIGH, WLOG_ERROR, 
  561.         "Error: reading directory %s, %s", 
  562.         index_dir, sys_errlist[errno]);
  563.     exit(1);
  564.   }
  565.   
  566.   /* ok. we know if we need indexing, 
  567.    * and have all the filenames. 
  568.    */
  569.   
  570.   if ((info_change_time == 0) || indexing_needed) {
  571.  
  572.     /* Time to re-index,
  573.      * aquire the lock 
  574.      */
  575.     waislog(WLOG_MEDIUM, WLOG_INDEX,
  576.         "re-indexing needed, info_change_time=%d",info_change_time); 
  577.  
  578.     if (( fd = open(LOCKFILE, O_WRONLY|O_CREAT|O_EXCL,0666)) == -1) {
  579.       
  580.       /* already locked by somebody else
  581.        * spin  till she finishes
  582.        */
  583.       while (!(stat(LOCKFILE,&statbuf) == -1)) {
  584.     sleep(NAPTIME);
  585.     naptime += NAPTIME;
  586.     waislog(WLOG_MEDIUM, WLOG_INFO,
  587.         "INFO locked, waiting since %d seconds", naptime);
  588.     if (naptime  > MAXNAPTIME)  {
  589.       waislog(WLOG_HIGH, WLOG_ERROR,
  590.           "Warning - lockfile %s wont go away after %d seconds, exiting", 
  591.           LOCKFILE, naptime);
  592.       exit(1);        /* XXX be more perseverant */
  593.     }
  594.       }
  595.       /* lockfile went away, assume INFO.* build finished
  596.        * so just use it
  597.        */
  598.     } else {            /* we aquired the lock, so rebuild database  */
  599.       
  600.       if (!(child = fork())) {
  601.     database *db;
  602.     struct dirent **s = list;
  603.     char filename[MAX_FILENAME_LEN];
  604.           
  605.     waislog(WLOG_MEDIUM, WLOG_INDEX,
  606.         "Creating INFO database, pid=%d",getpid());
  607.     db = openDatabase(merge_pathnames("INFO",    index_dir),
  608.               true, /* maybe this should append XXX */
  609.               false);
  610.     db->the_word_memory_hashtable =
  611.       init_word_memory_hashtable(1L<<16, 100000, db->the_word_memory_hashtable);
  612.           
  613.     while (*s) {        /* index it */
  614.       strncpy(filename, index_dir, MAX_FILENAME_LEN);
  615.       if(index_dir[strlen(index_dir) -1] != '/')
  616.         strncat(filename, "/", MAX_FILENAME_LEN);
  617.       strncat(filename, (*s)->d_name, MAX_FILENAME_LEN);
  618.       waislog(WLOG_MEDIUM, WLOG_INDEX,
  619.           "Indexing %s", filename);
  620.       index_text_file(filename, &dataops, db, true, false);
  621.       s++;
  622.     }
  623.     freedir(list);        /* array of filenames */
  624.           
  625.     if(!probe_file(source_filename(filename, db)))
  626.       write_src_structure(source_filename(filename, db),
  627.                   "INFO", "WSRC", NULL, 0, true, tcp_port);
  628.     finished_add_word(db);
  629.     closeDatabase(db);
  630.     if (unlink(LOCKFILE))
  631.       panic("Indexer: cant unlink lockfile!\n");
  632.     waislog(WLOG_MEDIUM, WLOG_INDEX,
  633.         "Indexer pid=%d done", getpid());
  634.           
  635.     exit(0);        /* indexing child */
  636.  
  637.       }  else if (child == -1) {
  638.     waislog(WLOG_HIGH, WLOG_ERROR,
  639.         "Unable to fork for indexer.");
  640.     exit(1);
  641.       }
  642.       /* wait for child process */
  643.       else while (wait(0) != child) ; /* do nothing */
  644.     }
  645.   }
  646.  
  647. #endif                /* AUTO_INDEX */
  648.  
  649.   waislog(WLOG_MEDIUM, WLOG_INFO, "Running server %s", VERSION);
  650.  
  651.   signal(SIGINT, breakKey);
  652.  
  653.   signal(SIGCHLD, childhandler); /* XXX dont really need this any more */
  654.   signal(SIGALRM, server_alarmhandler);
  655.  
  656.   signal(SIGSEGV, seghandler);
  657.  
  658.   signal(SIGBUS, bushandler);
  659.  
  660.   open_server(tcp_port,&socket,BUFSZ);
  661.  
  662. #ifdef SECURE_SERVER
  663.     /* if root, setuid to user specified id. */
  664.     if (uid > 0 && getuid() == 0)  {
  665.       waislog(WLOG_MEDIUM, WLOG_INFO,
  666.           "Setting uid to %s.", uid_name);
  667.       if ( 0 > setuid(uid)) {
  668.     waislog(WLOG_HIGH, WLOG_ERROR,
  669.         "Unable to setuid to %s!  Exiting.", uid_name);
  670.     exit(-1);
  671.       }
  672.     }
  673. #endif
  674.     while (TRUE) {        /* be a server for several connections */
  675.       int active, width = ulimit();
  676.  
  677.       FD_ZERO(&fds);
  678.       FD_SET(socket, &fds);
  679.       wais_pid = 0;
  680.       for (i = 0; i < 200; i++) {
  681.     if (clients[i].file != NULL)
  682.       FD_SET(fileno(clients[i].file), &fds);
  683.       }
  684.       if((active = select(width, &fds, NULL, NULL, NULL)) < 1) {
  685.     perror ("Select: ");
  686.     waislog(WLOG_HIGH, WLOG_ERROR, 
  687.         "select returned an error!");
  688.       }
  689.       else {
  690.     /* this is a connection on the socket. */
  691.     if (FD_ISSET(socket, &fds)) {
  692.       for(i = 0; i < 200; i++) {
  693.         if (clients[i].file == NULL) {
  694.           current_log_line++;
  695.           accept_client_connection(socket, &clients[i].file);
  696.           current_client = clients[i].file;
  697.           clients[i].buffersize = BUFSZ;
  698.           wais_pid = clients[i].pid = current_id++;
  699.           log_line = clients[i].line = 0;
  700.           if (handle_client(current_client, current_client, index_dir) == -1)  {
  701.         close_client_connection(current_client);
  702.         current_client = clients[i].file = NULL;
  703.         waislog(WLOG_MEDIUM, WLOG_CLOSE,
  704.             "Done handling client");
  705.         log_line = current_log_line;
  706.           }
  707.           else {
  708.         setitimer(ITIMER_REAL, &old, NULL);
  709.         clients[i].buffersize = bufferSize;
  710.         clients[i].line = log_line;
  711.         log_line = current_log_line;
  712.         wais_pid = 0;
  713.           }
  714.  
  715.           break;
  716.         }
  717.       }
  718.     }
  719.     /* this is for an established connection */
  720.  
  721.     for(i = 0; i < 200; i++) {
  722.       if(clients[i].file != NULL && FD_ISSET(fileno(clients[i].file), &fds)) {
  723.         current_client = clients[i].file;
  724.         bufferSize = clients[i].buffersize;
  725.         wais_pid = clients[i].pid;
  726.         log_line = clients[i].line;
  727.         if (handle_client(current_client, current_client, index_dir) == -1) {
  728.           close_client_connection(current_client);
  729.           current_client = clients[i].file = NULL;
  730.           waislog(WLOG_MEDIUM, WLOG_CLOSE,
  731.               "Done handling client");
  732.           wais_pid = 0;
  733.           log_line = current_log_line;
  734.         }
  735.         else setitimer(ITIMER_REAL, &old, NULL);
  736.         clients[i].line = log_line;
  737.       }
  738.     }
  739.       }
  740.     }
  741. }    
  742.  
  743. /*---------------------------------------------------------------------------*/
  744.  
  745.